package com.hospital.dao.impl;

import com.hospital.dao.WardDao;
import com.hospital.util.DruidUtil;

import java.sql.CallableStatement;
import java.sql.Connection;
import java.sql.SQLException;

/**
 * 病房数据访问对象实现类
 * 实现对病房信息的数据库操作，包括添加床位等功能
 */
public class WardDaoImpl implements WardDao {

    /**
     * 向指定病房添加一张床位
     * @param wardId 病房ID
     * @return 添加是否成功
     * @throws SQLException 如果数据库访问出错
     */
    @Override
    public boolean addBed(int wardId) throws SQLException {
        String sql = "{CALL add_bed(?)}";
        
        try (Connection conn = DruidUtil.getConnection();
             CallableStatement stmt = conn.prepareCall(sql)) {
            
            stmt.setInt(1, wardId);
            stmt.execute();
            return true;
            
        } catch (SQLException e) {
            e.printStackTrace();
            throw e;
        }
    }
} 